SparkN0de-git - /page/commit.mu

Micron Document

--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

| SparkN0de-git | SparkN0de |

Node / ReticulumProjects / LXMF.git / commits / f42ccfc

Commit f42ccfc4e93b9a85ed32a6ebc3b5f3ed21a24b49

󰉖 Browse tree at this commit

Parents : 9eca747

Author : Mark Qvist <mark@unsigned.io>

Date : 2025-01-30T11:23:18+01:00

Automatically clean messages exceeding propagation transfer limit for peer from unhandled message queues

Changes

1 files changed, 4 insertions(+), 1 deletions(-)

M LXMF/LXMPeer.py +4 -1

Diff

diff --git a/LXMF/LXMPeer.py b/LXMF/LXMPeer.py

index e2f951a..a777b86 100644

--- a/LXMF/LXMPeer.py

+++ b/LXMF/LXMPeer.py

@@ -250,7 +250,10 @@ class LXMPeer:

lxm_size = unhandled_entry[2]

next_size = cumulative_size + (lxm_size+per_message_overhead)

if self.propagation_transfer_limit != None and next_size > (self.propagation_transfer_limit*1000):

- pass

+ if lxm_size+per_message_overhead > self.propagation_transfer_limit:

+ RNS.log(f"Message {RNS.prettyhexrep(transient_id)} exceeds transfer limit for {self}, considering handled", RNS.LOG_DEBUG)

+ self.remove_unhandled_message(transient_id)

+ self.add_handled_message(transient_id)

else:

cumulative_size += (lxm_size+per_message_overhead)

unhandled_ids.append(transient_id)

──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────